SqlxTransaction

Constructors

Link copied to clipboard
constructor(rt: CPointer<out CPointed>, tx: CPointer<out CPointed>, encoders: ValueEncoderRegistry)

Properties

Link copied to clipboard
open override val commited: Boolean
Link copied to clipboard
open override val encoders: ValueEncoderRegistry
Link copied to clipboard
open override val rollbacked: Boolean
Link copied to clipboard
open override val status: Transaction.Status

Functions

Link copied to clipboard
open fun assertIsOpen()
Link copied to clipboard
open suspend override fun commit(): Result<Unit>
Link copied to clipboard
open suspend override fun execute(statement: Statement): Result<Long>
open suspend override fun execute(sql: String): Result<Long>
Link copied to clipboard
open suspend override fun executeWithResult(statement: Statement): Result<ExecuteResult>
open suspend override fun executeWithResult(sql: String): Result<ExecuteResult>
Link copied to clipboard
open fun <T> fetch(statement: Statement, rowMapper: RowMapper<T>, fetchSize: Int): Flow<T>
open fun <T> fetch(@Language(value = "SQL") sql: String, rowMapper: RowMapper<T>, fetchSize: Int): Flow<T>
open override fun fetch(statement: Statement, fetchSize: Int): Flow<ResultSet.Row>
open override fun fetch(sql: String, fetchSize: Int): Flow<ResultSet.Row>
Link copied to clipboard
open suspend fun <T> fetchAll(statement: Statement, rowMapper: RowMapper<T>): Result<List<T>>
open suspend fun <T> fetchAll(@Language(value = "SQL") sql: String, rowMapper: RowMapper<T>): Result<List<T>>
open suspend override fun fetchAll(statement: Statement): Result<ResultSet>
open suspend override fun fetchAll(sql: String): Result<ResultSet>
Link copied to clipboard
open suspend fun releaseSavepoint(name: String): Result<Unit>
Link copied to clipboard
open suspend override fun rollback(): Result<Unit>
Link copied to clipboard
open suspend fun rollbackToSavepoint(name: String): Result<Unit>
Link copied to clipboard
open suspend fun savepoint(name: String): Result<Unit>
open suspend fun <T> savepoint(name: String, f: suspend Transaction.() -> T): Result<T>